package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.ImportBinderConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.stereotype.Service;

/**
 * BI 消息队列
 * @author 梁鲁江
 * @version v1.0
 * @date 2019/4/23 9:29
 * @since v1.0
 */
@Service("biProducerBinder")
public interface ImportProducerBinder {
    /**
     * 导入新增数据 信道
     * @return
     */
    @Output(ImportBinderConstant.IMPORT_ADD)
    MessageChannel importAdd();

    /**
     * 导入大数据量新增 信道
     * @return
     */
    @Output(ImportBinderConstant.IMPORT_LARGE_NUM_ADD)
    MessageChannel importLargeNumAdd();
}
